package com.ruoyi.system.utils.rabbitMq.topic;//package com.letter.personal.util.rabbitMq.topic;
//
//import org.springframework.amqp.core.Message;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//@Component
//public class TopicSender implements RabbitTemplate.ReturnCallback {
//
//    @Autowired
//    //private AmqpTemplate rabbitTemplate;
//    private RabbitTemplate rabbitTemplate;
//
//	public void send(String count ) {
//        System.err.println("HelloSender发送内容 : " + count);
//        // this.rabbitTemplate.setConfirmCallback(this);
//        this.rabbitTemplate.setReturnCallback(this);
//        this.rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
//            if (!ack) {
//                System.err.println("HelloSender消息发送失败" + cause + correlationData.toString());
//            } else {
//                System.err.println("HelloSender 消息发送成功 ");
//            }
//        });
//		this.rabbitTemplate.convertAndSend("topicExchange", "topic.1", count);
//	}
//
//
//    //通过实现ReturnCallback接口，如果消息从交换器发送到对应队列失败时触发（比如根据发送消息时指定的routingKey找不到队列时会触发）
//    @Override
//    public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
//        System.out.println("消息主体message: " + message);
//        System.out.println("消息主体message: " + replyCode);
//        System.out.println("描述: " + replyText);
//        System.out.println("消息使用的交换器exchange: " + exchange);
//        System.out.println("消息使用的路由键routing: " + routingKey);
//    }
//}
